package br.com.academia.DAO;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

import br.com.academia.beans.Usuario;

public class UsuarioDAO {
	private Connection connection;
	
	public UsuarioDAO(Connection connection){
		this.connection = connection;
	}
	
	public Usuario retornaUsuario(Usuario usuario) {
		String query = "Select * from Usuarios where login = ? and senha = ?";
		try {
			PreparedStatement stm = connection.prepareStatement(query);
			stm.setString(1, usuario.getLogin());
			stm.setString(2, usuario.getSenha());
			
			ResultSet rs = stm.executeQuery();
			if(rs.next()) {
				usuario.setIdUsuario(rs.getInt("idUsuario"));
				usuario.setFuncionario_idFuncionario(rs.getInt("Funcionario_idFuncionario"));
			}
			
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return usuario;
	}
	
	public boolean validaUsuario(Usuario usuario) {
		String query = "Select * from Usuarios where login = ? and senha = ?";
		try {
			PreparedStatement stm = connection.prepareStatement(query);
			stm.setString(1, usuario.getLogin());
			stm.setString(2, usuario.getSenha());
			
			ResultSet rs = stm.executeQuery();
			if(rs.next()) {
				Usuario dadosLogin = new Usuario();
				dadosLogin.setIdUsuario(rs.getInt("idUsuario"));
			} else {
				return false;
			}
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return true;
	}
	
	public List<String[]> consultaUsuarios(List<String> dadosConsulta)  {
		List<String[]> retorno = new ArrayList<String[]>();
		String query = "Select idUsuario, Funcionario_idFuncionario, Funcionarios.nome, Funcionarios.sobreNome, login, senha From Usuarios " +
				"Left Join Funcionarios on Usuarios.Funcionario_idFuncionario = Funcionarios.idFuncionario";
		 try {
			 PreparedStatement stm = connection.prepareStatement(query);
			 ResultSet rs = stm.executeQuery();
			 while(rs.next()) {
				 String[] row = new String[dadosConsulta.size()];
				 for(int i = 0; i < row.length; i++) {
					 row[i] = rs.getString(dadosConsulta.get(i));
				 }
				 retorno.add(row);
			 }
		 } catch(SQLException e) {
			 e.printStackTrace();
		 }
		return retorno;
	}
	
	public Usuario consultaUsuarioId(int idUsuario) {
		Usuario usuario = new Usuario();
		String query = "Select * from Usuarios where idUsuario = ?";
		try {
			PreparedStatement stm = connection.prepareStatement(query);
			stm.setInt(1, idUsuario);
			ResultSet rs = stm.executeQuery();
			
			if(rs.next()) {
				usuario.setIdUsuario(rs.getInt("idUsuario"));
				usuario.setFuncionario_idFuncionario(rs.getInt("Funcionario_idFuncionario"));
				usuario.setLogin(rs.getString("login"));
				usuario.setSenha(rs.getString("senha"));
			}
		}catch(SQLException e) {
			e.printStackTrace();
		}
		
		return usuario;
	}
		
}
